package org.example.flink;

public class WordCountStreamDemo {
    public static void main(String[] args) throws Exception {
        //无界流监听
    }
}
